package org.example.mallchat.service.handler;

import me.chanjar.weixin.common.error.WxErrorException;
import me.chanjar.weixin.common.session.WxSessionManager;
import me.chanjar.weixin.mp.api.WxMpService;
import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage;
import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage;
import org.example.mallchat.service.WxMsgService;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.util.Map;

/**
 * @author ZZH
 * 这是一个专门处理微信公众号"关注"事件的Handler (也就是新用户关注公众号)
 */
@Component
public class SubscribeHandler extends AbstractHandler {

    @Resource
    private WxMsgService wxMsgService;

    @Override
    public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage,
                                    Map<String, Object> context, WxMpService weixinService,
                                    WxSessionManager sessionManager) throws WxErrorException {
        // 新用户关注公众号
        // 他关注事件获取到的code是和我们扫描事件的code是不一样的，所以这里需要后续处理 todo

        this.logger.info("新用户关注公众号" + wxMessage.getFromUser());
        // 进行返回点击授权登录url
        WxMpXmlOutMessage response = null;
        try {
            // 关注逻辑 - 和我们的扫码逻辑类似封装方法
            response = wxMsgService.scan(weixinService, wxMessage);
        }catch (Exception e){
            this.logger.error("关注事件处理失败", e);
        }
        if (response != null){
            return response;
        }
        return null;
    }

    /**
     * 处理特殊请求，比如如果是扫码进来的，可以做相应处理
     */
    private WxMpXmlOutMessage handleSpecial(WxMpService weixinService, WxMpXmlMessage wxMessage)
            throws Exception {
        return null;
//        return wxMsgService.scan(weixinService, wxMessage);
    }

}
